package dao

import (
	"context"
	"github.com/go-redis/redis/v8"
	"my_gin_blog/utils"
)

var RedisClient *redis.Client

// InitRedis 加载redis
func InitRedis() (err error) {
	RedisClient = redis.NewClient(&redis.Options{
		Addr:     utils.RedisHost + ":" + utils.RedisPort,
		Password: utils.RedisPwd,
		DB:       1,
	})
	ctx := context.Background()
	_, err = RedisClient.Ping(ctx).Result()
	if err != nil {
		return err
	}
	return nil
}

// CloseRedis 关闭redis
func CloseRedis() {
	if RedisClient != nil { //防止 对没有打开的redis 进行close
		err := RedisClient.Close()
		if err != nil {
			return
		}
	}
}
